package controller

import handler.DataHandler
import service.RealTimeAnalyse

/**
 * @author: Yan Tong xue
 * @Created:2024/3/19 14:20
 * @desc:
 */
class RealTimeAnalyseController {
  private val realTimeAnalyse = new RealTimeAnalyse

  def dispatch(): Unit = {
    val orderData = DataHandler.kafkaOrdersDatHandler("T2", "Graduation")
    realTimeAnalyse.dataAnalysis(orderData)
    DataHandler.startAndAwait()
  }

}
